package cc.autoapi.pucong.auto.flow.core.flow.execNode.streamBus;


/**
 * 消息执行
 */

@FunctionalInterface
public interface IStreamServiceEmitter {

    void run(String message);
}
